package com.baic.ibase.service.mqtt;


import org.springframework.integration.annotation.MessagingGateway;
import org.springframework.integration.mqtt.support.MqttHeaders;
import org.springframework.messaging.handler.annotation.Header;

public interface MqttSendService {

    void send(@Header(value = MqttHeaders.TOPIC)String topic, String message);

    void send(@Header(value = MqttHeaders.TOPIC) String topic, @Header(value = MqttHeaders.QOS) int qos, String message);


    void send(@Header(value = MqttHeaders.TOPIC) String topic, @Header(value = MqttHeaders.QOS) int qos, @Header(value = MqttHeaders.RETAINED) boolean retained, String message);

    void send(@Header(value = MqttHeaders.TOPIC) String topic, byte[] message);

    void send(@Header(value = MqttHeaders.TOPIC) String topic,@Header(value = MqttHeaders.QOS) int qos, byte[] message);

    void send(@Header(value = MqttHeaders.TOPIC) String topic, @Header(value = MqttHeaders.QOS) int qos,@Header(value = MqttHeaders.RETAINED) boolean retained,  byte[] message);


}
